//package com.topisv.tms.jms;
//
//import javax.jms.Destination;
//import javax.jms.JMSException;
//import javax.jms.Message;
//import javax.jms.Session;
//
//import org.slf4j.Logger;
//import org.slf4j.LoggerFactory;
//import org.springframework.jms.core.JmsTemplate;
//import org.springframework.jms.core.MessageCreator;
//
//import com.topisv.tms.jms.vo.SendMessage;
//
//
///**
// * 消息生产者
// * 
// * @author Administrator
// * 
// */
//public class SendMessageProducer {
//	
//	private static final Logger log = LoggerFactory.getLogger(SendMessageProducer.class);
//	
//	public void setJmsTemplate(JmsTemplate jmsTemplate) {
//		this.jmsTemplate = jmsTemplate;
//	}
//
//	public void setNotifyQueue(Destination notifyQueue) {
//		this.notifyQueue = notifyQueue;
//	}
//
//	public void setNotifyTopic(Destination notifyTopic) {
//		this.notifyTopic = notifyTopic;
//	}
//
//	
//	private JmsTemplate jmsTemplate;
//	
//	private Destination notifyQueue;
//	
//	private Destination notifyTopic;
//
//	/**
//	 * 发送队列消息
//	 * @param sendMessage
//	 */
//	public void sendQueue(final SendMessage sendMessage) {
//		sendMessage(sendMessage, notifyQueue);
//	}
//
//	/**
//	 * 发送订阅消息
//	 * @param sendMessage
//	 */
//	public void sendTopic(final SendMessage sendMessage) {
//		sendMessage(sendMessage, notifyTopic);
//	}
//
//	/**
//	 * 使用jmsTemplate的send/MessageCreator()发送Map类型的消息并在Message中附加属性用于消息过滤.
//	 */
//	private void sendMessage(final SendMessage sendMessage, Destination destination) {
//		jmsTemplate.send(destination, new MessageCreator() {
//			@Override
//			public Message createMessage(Session session) throws JMSException {
//				Message message = session.createMessage();
//				message.setStringProperty("type", sendMessage.getType());
//				message.setStringProperty("message", sendMessage.getMessage());
//				message.setStringProperty("objectType", "paiu");
//				log.info("发送消息类型："+sendMessage.getType());
//				log.info("发送消息内容："+sendMessage.getMessage());
//				return message;
//			}
//		});
//	}
//
//}
